package com.jarveis.dbs.core.init;

import java.io.IOException;

/**
 * 数据访问入口
 * 
 * @author liuguojun
 * @date 2014-06-05
 */
public class DBS4ZBus {

	public static void main(String[] args) throws IOException{
		/*
		RpcProcessor processor = new RpcProcessor();  
		processor.addModule(new DBServiceImpl());  
		
		Broker broker = new ZbusBroker("127.0.0.1:15555");

		ServiceConfig config = new ServiceConfig(); 
		config.setMq("DBSRpc");  
		config.setBroker(broker);    
		config.setMessageProcessor(processor); 
		config.setVerbose(true);
		config.setConsumerHandlerRunInPool(true); 
		config.setConsumerHandlerPoolSize(1024); 
		
		Service svc = new Service(config);
		svc.start();  
		*/
	}

}
